package com.jy.datapipeline.importserver.service;

import com.jy.datapipeline.common.exception.GlobalException;
import com.jy.datapipeline.importserver.entity.ImportRetrySubtask;

import java.util.List;
import java.util.Set;

/**
 * @类名 ImportRetrySubtaskService
 * @描述 TODO
 * @作者 白条君
 * @创建日期 2023/6/26 10:10
 * @版本 1.0
 */
public interface ImportRetrySubtaskService {

    void add(ImportRetrySubtask importRetrySubtask) throws GlobalException;

    List<ImportRetrySubtask> queryUnExecutionRetrySubtasks();

    void batchModifyRetrySubtaskStatus(Set<String> retrySubtaskIds) throws GlobalException;

    void deleteBySubtaskIds(Set<Long> ids) throws GlobalException;
}
